package org.jivesoftware.openfire.plugin.kafka;

import org.jivesoftware.util.JiveGlobals;

public class KafkaUtil {

    public static final String KAFKA_TOPIC_VALUE;

    static{
        KAFKA_TOPIC_VALUE = JiveGlobals.getProperty(KafkaUtil.KAFKA_TOPIC);
    }

    public static final String KAFKA_TOPIC = "kafka.topic";

    public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers";

    public static final String KAFKA_LINGER_MS = "kafka.linger.ms";

    public static final String KAFKA_BATCH_SIZE = "kafka.batch.size";

    public static final String KAFKA_BUFFER_MEMORY = "kafka.buffer.memory";

    public static final String KAFKA_MAX_POLL_RECORDS = "kafka.max.poll.records";

    public static final String KAFKA_GROUP_ID = "kafka.group.id";

    public static final String KAFKA_SESSION_TIMEOUT_MS = "kafka.session.timeout.ms";

}
